package com.jt.www.common.service;

import com.jt.www.model.entity.RabbitmqRecordEntity;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author admin_ltf
 * @create 2019-04-13 16:06
 * 检查mq消息消费的service
 */
@Service
public interface MessageConsumeService {

    void start();

    void consumeMessage(List<RabbitmqRecordEntity> rabbitmqRecordEntityList);

    void consumeMethod(RabbitmqRecordEntity entity);
}
